818acb3cecb98a3823711a73637107f224a9e8c1,cdap-data-fabric/src/main/java/co/cask/cdap/data/stream/service/ConcurrentStreamWriter.java,StreamFileFactory,create,#Id.Stream#,313
Before Change
FileWriter<StreamEvent> create(Id.Stream streamId) throws IOException {
StreamConfig streamConfig = streamAdmin.getConfig(streamId);
Integer generation = generations.get(streamId);
if (generation == null) {
generation = StreamUtils.getGeneration(streamConfig);
}
LOG.info("Create stream writer for {} with generation {}", streamId, generation);
After Change
*/
FileWriter<StreamEvent> create(Id.Stream streamId) throws IOException {
StreamConfig streamConfig = streamAdmin.getConfig(streamId);
int generation = StreamUtils.getGeneration(streamConfig);
LOG.info("Create stream writer for {} with generation {}", streamId, generation);
return writerFactory.create(streamConfig, generation);